
import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

/**
 *
 * @author cnavarro
 */
public class Recepteur extends Thread{

    //Données membres
    private int numPort;
    private Tampon tamponReception = new Tampon();
    
    // Constructeur
    public Recepteur(int numPort) {
        this.numPort = numPort;
    }
    
    @Override
    public void run ()
    {
        try
        {
            ServerSocket serverSocket = new ServerSocket (numPort);
            try
            {
                while (true)
                {
                    Socket socket = serverSocket.accept();
                    ObjectInputStream fluxDEntree = new ObjectInputStream (socket.getInputStream ());
                    
                    //Traitement
                    // Mise en mémoire tampon de réception
                    this.tamponReception.setElementTampon(fluxDEntree.toString());

                    //Fermeture de la socket
                    socket.close();
               }
            }
            catch (IOException e2)
            {
                System.err.println(e2.getMessage());
            }
        }
        catch (IOException e1)
        {
            System.err.println(e1.getMessage());
        }
    }

   public static void main(String[] args) 
   {
        System.out.println("-- Création du Recepteur :");
        Recepteur recepteur = new Recepteur(8081);
        recepteur.start();
   }

}
